package com.chis.flink;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.sink.PrintSinkFunction;

public class MySqlFlink {

    public static void main(String[] args) {
        try {
            StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
            env.addSource(new MySqlDsTest()).addSink(new MysqlDdTest<>());
            env.execute("ss sss");

        } catch (Exception e){
            e.printStackTrace();
        }

    }
}
